import threading
import socket
import time
import pickle


def client_tel():
	ip_port = ('127.0.0.1', 9999)

	s = socket.socket()     # 创建套接字

	s.connect(ip_port)      # 连接服务器

	while True:     # 通过一个死循环不断接收用户输入，并发送给服务器
	    # inp = input("请输入要发送的信息： ").strip()
	    inp = "我是客户端"
	    #inp = pickle.dumps()


	    time.sleep(1)

	    if not inp:     # 防止输入空信息，导致异常退出
	        continue
	    s.sendall(inp.encode())

	    if inp == "exit":   # 如果输入的是‘exit’，表示断开连接
	        print("结束通信！")
	        break

	    server_reply = s.recv(1024).decode()
	    print(server_reply)

	s.close()       # 关闭连接


def threadFunctionOne():
	while True:
		print("thread 1")
		time.sleep(2)
		


if __name__ == '__main__':
	thread_1 = threading.Thread(target=client_tel)
	thread_1.start()
	while True:
		print("main thread")
		time.sleep(1)

	thread_1.close()